Python mongo

安装

 $ python -m pip install pymongo
 $ pip list | grep pymongo
 > pymongo              4.6.1

数据库和集合

from pymongo import mongoClient

mongo = MongoClient("mongodb://localhost:27017") # 连接 mongo
dbs = mongo.list_database_names()                # 列出所有数据库

db = mongo['db']                                 # 按名称创建/获取数据库(数据库集合中创建元素后才实际创建数据库)
mongo.drop_database('db')                        # 删除数据库


collection = db['student']                       # 按名称创建/获取集合, 类似关系数据库中的表
db.drop_collection('student')                    # 删除集合

collection.rename('person')                      # 重命名集合

集合约束

ASCENDING: 升序
DESCENDING: 降序

from pymongo import ASCENDING

collection.create_index([("index", ASCENDING)])  # 集合按升序索引
collection.create_index([("index", ASCENDING)])  # 集合按降序索引

collection.create_index("index", unique=True)    # 集合按升序索引(默认值), 且 index 字段唯一

collection.create_index([                        # 复合唯一性约束
  ('field1', ASCENDING), ('field2', ASCENDING)],
  unique=True
)

collection.create_index(                         # 过期设定, 过期后自动删除
    [('expire_at', ASCENDING)],
    expireAfterSeconds=3600
)

Add

insert({key: value})

item = collection.insert_one(dict)               # 插入单个数据
item.inserted_id                                 # 插入数据的 id

collection.insert_one({'id':1, 'name': 'John'})

item = collection.insert_many(iterable[dict])    # 插入多个数据
item.inserted_ids                                # 打印多个插入数据的 id

collection.insert_many([
    {'id': i, 'value': v}
    for i, v in enumerate('abcd')
])

Query

find({key: {condation: value}})

更新方式	含义	示例
`$eq`	值等于,	`{'name': 'John'}` name 为 John 的数据
`$ne`	值不等于,	`{'name': {'$ne': 'John'}}` name 不等于 John 的值
`$lt, $lte`	小于, 小于等于	`{'num': {'$lt': 10}}` num 小于 10 的数据
`$gt, $gte`	大于, 大于等于	`{'num': {'$gte': 10}}` num 大于等于 10 的数据
`$in`	在范围内	`{'index': {'$in': [1, 2, 3]}}` index 的值是 1, 2, 3 的数据
`$regex`	符合正则表达式	`{'name': {'$regex': '^J'}}` name 符合正则的数据

逻辑与: {'num': {'$gt':10, '$lt': 20}} num 大于 10 且小于 20 的数据
逻辑或: {'$or': [{'name': 'John'}, {'index': 3}]} name 为 John 或 index 为 3 的数据

iten = collection.find_one(dict)                   # 查询单个数据 -> dict
data = collection.find_one({'id': 1})

items = collection.find(dict)                      # 查询多个数据 -> generation(仅能遍历一次)
items.count()                                      # 查询计数
for data in collection.find({'version': 'v1'}):
    print(data)

Update

update(query, update)
query 与查询一致, update 有多种方式

更新方式	含义	示例
`$set`	更新字段	`{'$set': {'name': 'John'}}` index 为 3 的数据, name 字段改为 John
`$inc`	字段值自增(可负数)	`{'$inc': {'n': 1}}` index 3 的数据, n 字段加 1
`$unset`	删除字段	`{'$unset': {'name': ""}}` 删除 `name` 字段
`$rename`	字段重命名	`{'$rename': {'name': 'username'}}` 重命名 `name` 字段
`$push`	数组结尾添加值	`{'$push': {'person': 'lily'}}` `person` 结尾添加 `lily` 元素
`$pop`	数组弹出一个元素	`{'$pop': {'person': 1}}` 1 表示末尾, -1 表示开头弹出
`$currentDate`	更新字段为当前日期	`{'$currentDate': {'update': True}}` 日期更新


collection.replace_one(dict, dict)               # 数据替换

item = collection.update_one(dict, dict)         # 更新指定单个数据的字段
item.matched_count                               # 匹配数量
item.modified_count                              # 修改数量
collection.update_one({'id': 1},{'$set': {'version', 'v2'}})

items = collection.update_many(dict, dict)       # 修改指定的所有数据字段
collection.update_one({'version': 'v1'},{'$set': {'version', 'v2'}})

collection.update_many(dict, dict)               # 数据替换, 原数据除 _id 外全删除, 替换为新的数据

collection.find_one({'index': 1})
> {'_id': ObjectId('54f4c5befba5220aa4d6dee7'), 'index': 1, 'name': 'John'}

collection.replace_one({'index': 1}, {'x': 2})
collection.find_one({'x': 2})
> {'_id': ObjectId('54f4c5befba5220aa4d6dee7'), 'x': 2}

Delete

update({key: {condation: value}}) 与 query 一致

item = collection.delete_one(dict)               # 删除匹配的单个数据
item.deleted_count                               # 删除数量
collection.delete_one({'index': 1})

collection.delete_many(dict)                     # 删除匹配的所有数据
collection.delete_many({'age': {'$gt': 18}})

Python mongo

Table of Contents

安装

数据库和集合

Add

Query

Update

Delete